package org.xq.softcup.mq.client.consumer;

import org.xq.softcup.mq.client.util.MqResult;

/**
 * 消费者接口
 */
public interface IMqConsumer {

    /**
     * 消费消息方法
     * @param data
     * @return
     * @throws Exception
     */
    public MqResult consume(String data) throws Exception;

}
